package com.hou.helloworld;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

//发送消息
public class Sender {
    public static void main(String[] args) throws JMSException {
        //1 创建ConnectionFactory工厂,  用户名  密码  连接url
        // 如果添加了安全机制,只有用有认证的用户去发送或者接受
        ConnectionFactory factory = new ActiveMQConnectionFactory(
                "houzheng",//默认的用户
                "houzheng",
                "tcp://localhost:61616"  //默认端口: 61616
        );
        //2 创建连接,并开启,默认是关闭的,并且完成后要关闭连接
        Connection connection = factory.createConnection();
        connection.start();
        //3 创建session   参数: 是否启用事务   选择签收模式(自动签收,客户端签收,不确认是否成功签收(消息可能崇重复))
        Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
        //4 创建Destination对象, 参数: 指定消息队列名称
        //Destination指的是消息的目的地或者消费来源,TPT模式中成为Queue,订阅/发布中称为主题
        Destination destination=session.createQueue("myqueue");
        //5 通过session对象创建消息的发送者或者接受者
        MessageProducer producer = session.createProducer(destination);//传入Destination
        //6 可以设置持久化或者非持久化
        producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
        //7 发送消息并关闭连接,可发送多种定义格式的消息
        for (int i = 0; i < 5; i++) {
            TextMessage textMessage = session.createTextMessage();
            textMessage.setText("我是第"+i+"条消息");
            producer.send(textMessage);
        }
        //如果开启了事务,则必须要提交才能全部发送到服务器
        //session.commit();
        if(connection!=null)connection.close();
    }
}
